🌚🌞

ClickHouse Integration tests (asan, old analyzer) [6/6] for PR #1707

integration_run_test_storage_kafka_test_py_0.log.zst Commit check_status.tsv install_clickhouse-client_24.8.14.10545.altinitytest+asan_amd64.deb.log install_clickhouse-common-static-dbg_24.8.14.10545.altinitytest+asan_amd64.deb.log install_clickhouse-common-static_24.8.14.10545.altinitytest+asan_amd64.deb.log install_clickhouse-library-bridge_24.8.14.10545.altinitytest+asan_amd64.deb.log install_clickhouse-odbc-bridge_24.8.14.10545.altinitytest+asan_amd64.deb.log install_clickhouse-server_24.8.14.10545.altinitytest+asan_amd64.deb.log integration_run_test_cross_replication_test_py_0.log integration_run_test_cross_replication_test_py_0.tar.zst integration_run_test_ddl_worker_non_leader_test_py_0.log integration_run_test_ddl_worker_non_leader_test_py_0.tar.zst integration_run_test_delayed_replica_failover_test_py_0.log integration_run_test_delayed_replica_failover_test_py_0.tar.zst integration_run_test_dictionary_allow_read_expired_keys_test_dict_get_or_default_py_0.log integration_run_test_dictionary_allow_read_expired_keys_test_dict_get_or_default_py_0.tar.zst integration_run_test_insert_into_distributed_test_py_0.log integration_run_test_insert_into_distributed_test_py_0.tar.zst integration_run_test_insert_into_distributed_through_materialized_view_test_py_0.log integration_run_test_insert_into_distributed_through_materialized_view_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst runner_get_all_tests.log test_results.tsv Task (github actions) Job (github actions)

Test name	Test status	Test time, sec.	Logs
Job Timeout Expired	FAIL	14287.337154
test_storage_kafka/test.py::test_row_based_formats[generate_old_create_table_query]	ERROR	163.04	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_virtual_columns2[generate_new_create_table_query-kafka.*Saved offset 2 for topic-partition \\[virt2_[01]:[0-9]+]	ERROR	22.11	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_virtual_columns	ERROR	9.69	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_num_consumers_limit[generate_old_create_table_query]	ERROR	2.44	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_multiple_read_in_materialized_views[generate_new_create_table_query]	ERROR	21.46	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_row_based_formats[generate_new_create_table_query]	ERROR	196.14	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_unavailable[generate_new_create_table_query-False]	ERROR	221.09	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_system_kafka_consumers_rebalance_mv	ERROR	31.55	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_virtual_columns_with_materialized_view[generate_old_create_table_query]	ERROR	10.4	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_virtual_columns2[generate_old_create_table_query-kafka.*Committed offset 2.*virt2_[01]]	ERROR	12.14	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_multiple_read_in_materialized_views[generate_old_create_table_query]	ERROR	20.78	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_system_kafka_consumers_rebalance	ERROR	35.57	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_system_kafka_consumers	ERROR	11.75	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_max_rows_per_message[generate_new_create_table_query]	ERROR	11.92	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_premature_flush_on_eof[generate_old_create_table_query]	ERROR	11.09	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_librdkafka_compression[generate_new_create_table_query-kafka.*Saved offset [0-9]+ for topic-partition \\[{topic}:[0-9]+\\]]	ERROR	34.54	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_max_rows_per_message[generate_old_create_table_query]	ERROR	10.6	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_virtual_columns_with_materialized_view[generate_new_create_table_query]	ERROR	11.55	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_premature_flush_on_eof[generate_new_create_table_query]	ERROR	11.08	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_librdkafka_compression[generate_old_create_table_query-Committed offset {offset}]	ERROR	40.05	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_num_consumers_limit[generate_new_create_table_query]	ERROR	22.62	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_bad_reschedule	ERROR	0.0
test_storage_kafka/test.py::test_block_based_formats_1	ERROR	0.0
test_storage_kafka/test.py::test_block_based_formats_2	ERROR	0.0
test_storage_kafka/test.py::test_commits_of_unprocessed_messages_on_drop	ERROR	0.0
test_storage_kafka/test.py::test_format_with_prefix_and_suffix	ERROR	0.0
test_storage_kafka/test.py::test_issue26643	ERROR	0.0
test_storage_kafka/test.py::test_kafka_column_types	ERROR	0.0
test_storage_kafka/test.py::test_kafka_commit_on_block_write	ERROR	0.0
test_storage_kafka/test.py::test_kafka_consumer_failover	ERROR	0.0
test_storage_kafka/test.py::test_kafka_engine_put_errors_to_stream	ERROR	0.0
test_storage_kafka/test.py::test_kafka_engine_put_errors_to_stream_with_random_malformed_json	ERROR	0.0
test_storage_kafka/test.py::test_kafka_flush_by_block_size	ERROR	0.0
test_storage_kafka/test.py::test_kafka_flush_by_time	ERROR	0.0
test_storage_kafka/test.py::test_kafka_flush_on_big_message	ERROR	0.0
test_storage_kafka/test.py::test_kafka_formats	ERROR	0.0
test_storage_kafka/test.py::test_kafka_formats_with_broken_message	ERROR	0.0
test_storage_kafka/test.py::test_kafka_insert	ERROR	0.0
test_storage_kafka/test.py::test_kafka_insert_avro	ERROR	0.0
test_storage_kafka/test.py::test_kafka_issue14202	ERROR	0.0
test_storage_kafka/test.py::test_kafka_lot_of_partitions_partial_commit_of_bulk	ERROR	0.0
test_storage_kafka/test.py::test_kafka_many_materialized_views	ERROR	0.0
test_storage_kafka/test.py::test_kafka_materialized_view	ERROR	0.0
test_storage_kafka/test.py::test_kafka_materialized_view_with_subquery	ERROR	0.0
test_storage_kafka/test.py::test_kafka_no_holes_when_write_suffix_failed	ERROR	0.0
test_storage_kafka/test.py::test_kafka_null_message	ERROR	0.0
test_storage_kafka/test.py::test_kafka_produce_consume	ERROR	0.0
test_storage_kafka/test.py::test_kafka_produce_consume_avro	ERROR	0.0
test_storage_kafka/test.py::test_kafka_produce_key_timestamp	ERROR	0.0
test_storage_kafka/test.py::test_kafka_producer_consumer_separate_settings	ERROR	0.0
test_storage_kafka/test.py::test_kafka_rebalance	ERROR	0.0
test_storage_kafka/test.py::test_kafka_recreate_kafka_table	ERROR	0.0
test_storage_kafka/test.py::test_kafka_unavailable	ERROR	0.0
test_storage_kafka/test.py::test_kafka_virtual_columns2	ERROR	0.0
test_storage_kafka/test.py::test_kafka_virtual_columns_with_materialized_view	ERROR	0.0
test_storage_kafka/test.py::test_librdkafka_compression	ERROR	0.0
test_storage_kafka/test.py::test_max_rows_per_message	ERROR	0.0
test_storage_kafka/test.py::test_multiple_read_in_materialized_views	ERROR	0.0
test_storage_kafka/test.py::test_num_consumers_limit	ERROR	0.0
test_storage_kafka/test.py::test_premature_flush_on_eof	ERROR	0.0
test_storage_kafka/test.py::test_row_based_formats	ERROR	0.0
test_cross_replication/test.py::test	OK	437.63	integration_run_test_cross_replication_test_py_0.log integration_run_test_cross_replication_test_py_0.tar.zst
test_ddl_worker_non_leader/test.py::test_non_leader_replica	OK	89.71	integration_run_test_ddl_worker_non_leader_test_py_0.log integration_run_test_ddl_worker_non_leader_test_py_0.tar.zst
test_delayed_replica_failover/test.py::test	OK	698.16	integration_run_test_delayed_replica_failover_test_py_0.log integration_run_test_delayed_replica_failover_test_py_0.tar.zst
test_dictionary_allow_read_expired_keys/test_dict_get_or_default.py::test_simple_dict_get_or_default	OK	81.44	integration_run_test_dictionary_allow_read_expired_keys_test_dict_get_or_default_py_0.log integration_run_test_dictionary_allow_read_expired_keys_test_dict_get_or_default_py_0.tar.zst
test_insert_into_distributed/test.py::test_reconnect	OK	28.25	integration_run_test_insert_into_distributed_test_py_0.log integration_run_test_insert_into_distributed_test_py_0.tar.zst
test_insert_into_distributed/test.py::test_inserts_batching	OK	172.93	integration_run_test_insert_into_distributed_test_py_0.log integration_run_test_insert_into_distributed_test_py_0.tar.zst
test_insert_into_distributed_through_materialized_view/test.py::test_reconnect	OK	76.95	integration_run_test_insert_into_distributed_through_materialized_view_test_py_0.log integration_run_test_insert_into_distributed_through_materialized_view_test_py_0.tar.zst
test_storage_kafka/test.py::test_kafka_no_holes_when_write_suffix_failed[generate_old_create_table_query]	OK	35.32	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_consumer_failover[generate_new_create_table_query]	OK	159.35	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_lot_of_partitions_partial_commit_of_bulk[generate_old_create_table_query]	OK	19.05	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_protobuf_no_delimiter	OK	10.5	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_issue26643[generate_new_create_table_query]	OK	10.88	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_producer_consumer_separate_settings[generate_new_create_table_query-False]	OK	8.5	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_flush_by_block_size[generate_new_create_table_query]	OK	20.56	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_many_materialized_views[generate_new_create_table_query]	OK	12.61	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_recreate_kafka_table[generate_new_create_table_query-kafka.*Saved offset [0-9]+ for topic-partition \\[recreate_kafka_table:[0-9]+]	OK	23.18	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_issue11308	OK	8.61	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_protobuf	OK	6.31	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_exception_from_destructor	OK	4.13	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_engine_put_errors_to_stream_with_random_malformed_json[generate_new_create_table_query]	OK	18.26	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_null_message[generate_old_create_table_query]	OK	15.52	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_rebalance[generate_new_create_table_query-{}.*Saved offset]	OK	107.03	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_flush_by_block_size[generate_old_create_table_query]	OK	19.22	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_flush_by_time[generate_old_create_table_query]	OK	26.85	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_produce_consume_avro[generate_old_create_table_query]	OK	14.19	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_issue14202[generate_old_create_table_query]	OK	3.54	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_commits_of_unprocessed_messages_on_drop[generate_new_create_table_query]	OK	19.92	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_column_types[generate_old_create_table_query-True]	OK	12.03	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_format_with_prefix_and_suffix[generate_old_create_table_query]	OK	2.78	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_json_as_string	OK	6.81	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_materialized_view_with_subquery[generate_old_create_table_query]	OK	14.1	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_formats_with_broken_message[generate_new_create_table_query]	OK	88.37	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_flush_on_big_message[generate_old_create_table_query]	OK	111.66	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_produce_key_timestamp[generate_old_create_table_query-Committed offset 5]	OK	15.22	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_commits_of_unprocessed_messages_on_drop[generate_old_create_table_query]	OK	23.49	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_duplicates_when_commit_failed	OK	59.72	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_insert[generate_old_create_table_query]	OK	7.27	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_settings_predefined_macros	OK	6.35	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_consumer_failover[generate_old_create_table_query]	OK	169.56	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_flush_on_big_message[generate_new_create_table_query]	OK	130.75	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_commit_on_block_write[generate_new_create_table_query]	OK	22.52	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_consumer_hang2	OK	30.98	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_produce_consume[generate_old_create_table_query]	OK	37.88	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_csv_with_thread_per_consumer	OK	13.9	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_settings_new_syntax	OK	7.49	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_predefined_configuration	OK	6.25	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_produce_key_timestamp[generate_new_create_table_query-Saved offset 5]	OK	14.59	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_settings_old_syntax	OK	7.31	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_recreate_kafka_table[generate_old_create_table_query-kafka.*Committed offset [0-9]+.*recreate_kafka_table]	OK	19.54	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_insert_avro[generate_old_create_table_query]	OK	3.05	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_formats_with_broken_message[generate_old_create_table_query]	OK	50.47	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_produce_consume[generate_new_create_table_query]	OK	32.41	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_column_types[generate_new_create_table_query-False]	OK	2.11	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_materialized_view[generate_old_create_table_query]	OK	13.16	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_rebalance[generate_old_create_table_query-{}.*Polled offset [0-9]+]	OK	94.43	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_lot_of_partitions_partial_commit_of_bulk[generate_new_create_table_query]	OK	20.55	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_produce_consume_avro[generate_new_create_table_query]	OK	11.53	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_json_without_delimiter	OK	6.41	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_engine_put_errors_to_stream[generate_old_create_table_query]	OK	8.7	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_null_message[generate_new_create_table_query]	OK	15.23	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_issue26643[generate_old_create_table_query]	OK	10.87	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_producer_consumer_separate_settings[generate_old_create_table_query-True]	OK	9.28	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_engine_put_errors_to_stream[generate_new_create_table_query]	OK	12.02	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_materialized_view[generate_new_create_table_query]	OK	14.86	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_flush_by_time[generate_new_create_table_query]	OK	22.0	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_block_based_formats_2[generate_new_create_table_query]	OK	78.16	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_block_based_formats_1[generate_old_create_table_query]	OK	4.5	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_insert[generate_new_create_table_query]	OK	3.59	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_formats_errors	OK	243.1	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_select_empty	OK	10.65	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_read_consumers_in_parallel	OK	24.4	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_block_based_formats_1[generate_new_create_table_query]	OK	2.23	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_materialized_view_with_subquery[generate_new_create_table_query]	OK	10.7	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_consumer_hang	OK	34.28	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_issue14202[generate_new_create_table_query]	OK	3.35	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_bad_reschedule[generate_old_create_table_query]	OK	349.9	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_commit_on_block_write[generate_old_create_table_query]	OK	17.63	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_csv_with_delimiter	OK	6.11	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_issue4116	OK	6.04	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_insert_avro[generate_new_create_table_query]	OK	3.58	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_engine_put_errors_to_stream_with_random_malformed_json[generate_old_create_table_query]	OK	13.77	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_format_with_prefix_and_suffix[generate_new_create_table_query]	OK	2.66	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_block_based_formats_2[generate_old_create_table_query]	OK	59.36	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_string_field_on_first_position_in_protobuf	OK	6.19	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_bad_reschedule[generate_new_create_table_query]	OK	175.22	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_many_materialized_views[generate_old_create_table_query]	OK	12.01	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_tsv_with_delimiter	OK	7.04	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_formats[generate_old_create_table_query]	OK	64.35	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_formats[generate_new_create_table_query]	OK	124.51	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_num_consumers_limit[generate_old_create_table_query]	OK	2.44	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_multiple_read_in_materialized_views[generate_new_create_table_query]	OK	21.46	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_virtual_columns_with_materialized_view[generate_old_create_table_query]	OK	10.4	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_system_kafka_consumers	OK	11.75	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_librdkafka_compression[generate_new_create_table_query-kafka.*Saved offset [0-9]+ for topic-partition \\[{topic}:[0-9]+\\]]	OK	34.54	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_system_kafka_consumers_rebalance_mv	OK	31.55	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_virtual_columns2[generate_old_create_table_query-kafka.*Committed offset 2.*virt2_[01]]	OK	12.14	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_premature_flush_on_eof[generate_old_create_table_query]	OK	11.09	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_virtual_columns_with_materialized_view[generate_new_create_table_query]	OK	11.55	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_premature_flush_on_eof[generate_new_create_table_query]	OK	11.08	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_row_based_formats[generate_new_create_table_query]	OK	196.14	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_unavailable[generate_old_create_table_query-True]	OK	240.08	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_multiple_read_in_materialized_views[generate_old_create_table_query]	OK	20.78	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_max_rows_per_message[generate_new_create_table_query]	OK	11.92	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_max_rows_per_message[generate_old_create_table_query]	OK	10.6	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_num_consumers_limit[generate_new_create_table_query]	OK	22.62	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_row_based_formats[generate_old_create_table_query]	OK	163.04	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_virtual_columns2[generate_new_create_table_query-kafka.*Saved offset 2 for topic-partition \\[virt2_[01]:[0-9]+]	OK	22.11	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_virtual_columns	OK	9.69	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_kafka_unavailable[generate_new_create_table_query-False]	OK	221.09	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_system_kafka_consumers_rebalance	OK	35.57	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst
test_storage_kafka/test.py::test_librdkafka_compression[generate_old_create_table_query-Committed offset {offset}]	OK	40.05	integration_run_test_storage_kafka_test_py_0.log.zst integration_run_test_storage_kafka_test_py_0.tar.zst integration_run_test_storage_kafka_test_py_1.log integration_run_test_storage_kafka_test_py_1.tar.zst integration_run_test_storage_kafka_test_py_2.log integration_run_test_storage_kafka_test_py_2.tar.zst